package com.twang.stock.task;

import com.twang.stock.service.MinutesChengJIaoeService;
import com.twang.stock.task.old.BaseTask;
import com.twang.stock.threadPool.AsycTaskExecutorConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * @param ：
 * 每日14：57更新
 * 即时--http://data.10jqka.com.cn/funds/gnzjl/ajax/1/free/1/
 *             3日：http://data.10jqka.com.cn/funds/gnzjl/board/3/ajax/1/free/1/
 *             5日：http://data.10jqka.com.cn/funds/gnzjl/board/5/ajax/1/free/1/
 *           明细：http://q.10jqka.com.cn/gn/detail/code/300845/
 */
@Slf4j
@Component
public class StockLastChengJiaoETask extends BaseTask {


    @Autowired
    private StockMinutesTask stockMinutesTask;

    @Autowired
    private MinutesChengJIaoeService minutesChengJIaoeService;

    @Autowired
    private AsycTaskExecutorConfig asycTaskExecutorConfig;
    @Scheduled(cron = "0 30 15 * * ? ")
    public void excute() {
        if (!isWork()) {
            return;
        }
        asycTaskExecutorConfig.taskQueueExecutor().execute(() -> {
            try {
                //成交额初始化
                stockMinutesTask.extractedChengJiaoe();

                //生成当天的数据
                minutesChengJIaoeService.getTodayVolumeExceedingBillion("");

                //执行预警
                stockMinutesTask.updateTimes();
            } catch (Exception e) {
                log.info("error = {}", e);
            }
            log.info("==========> 消息刷新  TodayReDuOnehourTask end!");
        });
    }

}
